import pymysql
class Model():
    Mysql_localhost='localhost'
    Mysql_username='root'
    Mysql_password='root'
    Mysql_select_DB='dbs'
    Mysql_charset='utf8mb4'
    Mysql_cursorclass=pymysql.cursors.DictCursor
    Mysql_link=''
    Mysql_cursor=''

    #链接数据库
    def __init__(self):
        #打开数据库
        self.Mysql_link=pymysql.connect(self.Mysql_localhost,self.Mysql_username,self.Mysql_password,self.Mysql_select_DB,
             charset=self.Mysql_charset,cursorclass=self.Mysql_cursorclass)
        #获取游标对象
        self.Mysql_cursor=self.Mysql_link.cursor()
    #查询
    def query(self,sql):
        self.Mysql_cursor.execute(sql)
        # 返回结果 查询集合
        return self.Mysql_cursor.fetchall()



    #写操作
    def exec(self,sql):
        try:
            #执行
            self.Mysql_cursor.execute(sql)
            self.Mysql_link.commit()
            #返回受影响行数
            num=self.Mysql_cursor.rowcount
            return num
        except:
            self.Mysql_link.rollback()
            return False

    #关闭数据库链接
    def __del__(self):
        #析构函数 当对象结束是自动出发
        self.Mysql_link.close()

#b=Model()
